"""
kafka消费者
在yjf这个topic中配置了三个分区以及三个broker
1.生产者一共发放了三个分区,所以每一个消费者应该只有一个分区(如果是临时加入的消费者,那么会导致四个分区中后面有一个分区不会再去消费数据)
2.
"""
import json

from kafka import KafkaConsumer

res = KafkaConsumer("new", bootstrap_servers='10.90.93.29:9092', group_id="y")
print('customer1消费者连接服务器成功')
for data in res:
    receive_value = json.loads(data.value.decode('utf-8'))
    print("topic=%s partition=%d offset=%d value=%s" % (data.topic, data.partition, data.offset, receive_value))
